
from gevent import monkey

monkey.patch_all()
from gevent.pool import Pool as BasePool


# 自定义 自己的协程 close  errorback

class Pool(BasePool):
    # 1.errorback
    def apply_async(self, func, args=(), kwds={}, callback=None,
                    error_callback=None):
        return super().apply_async(func, args=args, kwds=kwds, callback=callback)

    # 2. close
    def close(self):
        pass

